//package com.netgov.admin.task;
//
//import com.netgov.admin.service.BigScreenService;
//import com.netgov.common.utils.DateUtilsEx;
//import com.netgov.common.utils.ThreadUtil;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.data.redis.core.RedisTemplate;
//import org.springframework.scheduling.annotation.Scheduled;
//import org.springframework.stereotype.Component;
//
//import java.util.Date;
//import java.util.concurrent.TimeUnit;
//
///**
// * @author hui
// * @Date 2024/4/20 15:59
// **/
//@Slf4j
//@Component
//public class SseTask {
//
//    @Autowired
//    private RedisTemplate redisTemplate;
//
//    @Autowired
//    private BigScreenService bigScreenService;
//
//    @Scheduled(cron = "30 */2 * * * ?")
//    public void checkLackAttendance() {
//        ThreadUtil.getThreadPool().execute(new Runnable() {
//            @Override
//            public void run() {
//                if (!redisTemplate.opsForValue().setIfAbsent("sseDataTask", DateUtilsEx.getStringDateTime(new Date()),30, TimeUnit.MINUTES)) {
//                    log.info("checkTemparyClickProgressing!");
//                    return;
//                }
//                log.info("大屏数据推送任务开始");
//                Date current = new Date();
//                try {
////                    attendanceService.update(new LambdaUpdateWrapper<UserAttendance>().set(UserAttendance::getStatus, 2).le(UserAttendance::getDutyEndTime, current).eq(UserAttendance::getStatus, 0));
//                } finally {
//                    redisTemplate.delete("sseDataTask");
//                }
//                log.info("大屏数据推送任务结束");
//            }
//        });
//    }
//
//
//
//
//}
